package com.nuanshui.heatedloan.task.facade;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

import com.alibaba.fastjson.JSON;
import com.nuanshui.heatedloan.middleware.rabbitmq.message.RabbitmqMessage;
import com.nuanshui.heatedloan.task.constant.TaskGlobalParams;

/**
 * 定时任务消息发送工具类
 * @param 
 * @author guohao
 * @date 2017年2月13日 上午9:47:25
 * @since $
 */
@Component
public class TaskMessageSender {
	
	@Autowired
	private AmqpTemplate amqpTemplate;

	@Value("${mq.message.suffix}")
	private String suffix = "";
	
	/**
	 * 发送消息
	 * 
	 * @param
	 * @author guohao
	 * @date 2016年3月1日 下午2:42:53
	 */
	private  void send(RabbitmqMessage rabbitmqMessage) {

		amqpTemplate.convertAndSend(TaskGlobalParams.JOB_MESSAGE_EXCHANGE,rabbitmqMessage.getQueue(),rabbitmqMessage.getBody());

	}
	
	public void send(String queue,Object params) {
		RabbitmqMessage rabbitmqMessage = new RabbitmqMessage();
		rabbitmqMessage.setBody(JSON.toJSONString(params));
		
		rabbitmqMessage.setQueue(queue);
		this.send(rabbitmqMessage);
	}
	
	

}
